const mqtt = require('mqtt');

// 连接到 MQTT 代理
// const client = mqtt.connect('mqtt://47.93.216.41:1883'); // 请替换为您的 MQTT 代理地址
const client = mqtt.connect('mqtt://47.101.172.203:1883'); // 请替换为您的 MQTT 代理地址

const baseCoord = {
    'lng': 116297611, // 116.297611
    'lat': 40047363 // 40.047363
}
const getRandomValue = () => {
    const arr = ['lng', 'lat']
    const randomIndex = Math.floor(Math.random() * arr.length);
    return arr[randomIndex];
}

// 成功连接后的回调函数
client.on('connect', () => {
    console.log('成功链接demo1-topic');
    // 发布消息到主题
    setInterval(() => {
        const rd = getRandomValue()
        baseCoord[rd] = baseCoord[rd] + 10
        client.publish('demo1', JSON.stringify(baseCoord)); // 请替换为您要发布的主题和消息内容
    }, 500)

    // 订阅主题
    // client.subscribe('topic_name'); // 请替换为您要订阅的主题
});

// 收到消息的回调函数
client.on('message', (topic, message) => {
    console.log('Received message:', message.toString());
});

// 断开连接后的回调函数
client.on('close', () => {
    console.log('Disconnected from MQTT broker');
});
